// package org.example;
//
// import io.netty.buffer.ByteBuf;
// import io.netty.channel.ChannelHandlerContext;
// import io.netty.handler.codec.MessageToByteEncoder;
// import org.example.protobuf.MsgProto;
//
// /**
//  * @author hh
//  * @since 2024/11/24
//  */
// public class ProtobufEncoder extends MessageToByteEncoder<MsgProto.Msg>{
//
//     @Override
//     protected void encode(ChannelHandlerContext channelHandlerContext, MsgProto.Msg msg, ByteBuf out) throws Exception {
//         // 将对象转换为字节
//         byte[] byteArray = msg.toByteArray();
//         int length = byteArray.length;
//         // 将消息长度写入，这里只用两个字节，最大为32767
//         out.writeShort(length);
//         // 消息体中包含我们要发送的数据
//         out.writeBytes(msg.toByteArray());
//     }
// }
